package job

import (
	"fmt"
	"test/queue"
)

// 消费者
func NewJobTwoQueue() *One {
	var job = &One{}
	job.QueueName = "queue/two"
	return job
}

type Two struct {
	queue.JobImplement // 继承
	Data interface{}
}

func (job *Two) Handle(data interface{}) {
	fmt.Printf("进来消费job two: %v\n", data)
}
